package Hudi_SelfStudy.spark_shell_study

import org.apache.spark.sql.SparkSession

object study_02 {
  def main(args: Array[String]): Unit = {
    /*
        时间旅行:查询到指定时间前的，最新的数据,如果指定的时间就是最早的，那么就返回指定时间插入的数据(要注意的是，是指定时间前的所有数据，而不是最
        新插入的数据)

        fileName:时间旅行查询的方式
     */


    //  准备sparksql集成hudi的环境
    val spark = SparkSession.builder()
      .master("local[*]")
      .appName("查看数据")
      .config("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
      .config("spark.sql.extensions", "org.apache.spark.sql.hudi.HoodieSparkSessionExtension")
      .enableHiveSupport()
      .getOrCreate()

    //  数据文件保存的路径
    val data_path="hdfs://192.168.40.110:9000/user/hudi/hudi_trips_cow"

    //  时间旅行的三种方式   instant:瞬间
    spark.read.format("hudi")
      .option("as.of.instant","20210728141108100")
      .load(data_path)

    spark.read.format("hudi")
      .option("as.of.instant","2021-07-28 14:11:08.200")
      .load(data_path)
    //  没有指定时分秒就是代表00:00:00
    spark.read.format("hudi")
      .option("as.of.instant","2021-07-28")
      .load(data_path)





    spark.close()

  }

}
